#ifndef LOCKER_H
#define LOCKER_H
#include <exception>
#include <pthread.h>
#include <semaphore.h>

// 线程同步机制封装类

// 互斥锁类
class locker
{
public:
    locker()
    {
        // 初始化互斥锁。如果初始化失败，则抛出 std::exception 异常。
        if (pthread_mutex_init(&m_mutex, NULL) != 0)
        {
            throw std::exception();
        }
    }

    ~locker()
    {
        // 类的析构函数，用于销毁互斥锁。
        pthread_mutex_destroy(&m_mutex);
    }

    bool lock()
    {
        // 返回值为 0 表示加锁成功，返回值为其他数值表示加锁失败。
        // 类的成员函数，用于对互斥锁进行加锁操作。返回值为布尔类型，表示加锁是否成功。
        return pthread_mutex_lock(&m_mutex) == 0;
    }

    bool unlock()
    {
        // 类的成员函数，用于对互斥锁进行解锁操作。返回值为布尔类型，表示解锁是否成功。
        return pthread_mutex_unlock(&m_mutex) == 0;
    }

    pthread_mutex_t *get()
    {
        // 类的成员函数，用于获取互斥锁的指针。
        return &m_mutex;
    }

private:
    pthread_mutex_t m_mutex;
};

// 条件变量类
class cond
{
public:
    cond()
    {
        // 初始化条件变量。如果初始化失败，则抛出 std::exception 异常。
        if (pthread_cond_init(&m_cond, NULL) != 0)
        {
            throw std::exception();
        }
    }
    ~cond()
    {
        // 类的析构函数，用于销毁条件变量。
        pthread_cond_destroy(&m_cond);
    }

    bool wait(pthread_mutex_t *m_mutex)
    {
        // 类的成员函数，用于等待条件变量。函数参数为一个互斥锁的指针，用于对互斥锁进行加锁操作。
        // 返回值为布尔类型，表示等待操作是否成功。
        int ret = 0;
        ret = pthread_cond_wait(&m_cond, m_mutex);
        return ret == 0;
    }
    bool timewait(pthread_mutex_t *m_mutex, struct timespec t)
    {
        // 类的成员函数，用于等待条件变量并设置等待时间。
        // 函数参数分别为一个互斥锁的指针和一个时间结构体，用于对互斥锁进行加锁操作和设置等待时间。
        // 如果在等待时间内条件变量被其他线程发送信号，则函数会解锁互斥锁并返回 true；
        // 如果等待时间内没有收到信号，则函数会解锁互斥锁并返回 false。
        int ret = 0;
        ret = pthread_cond_timedwait(&m_cond, m_mutex, &t);
        return ret == 0;
    }
    bool signal()
    {
        // 向等待该条件变量的一个线程发送信号。
        // 该函数会向等待队列中的第一个线程发送信号唤醒它。
        return pthread_cond_signal(&m_cond) == 0;
    }
    bool broadcast()
    {
        // 向所有等待该条件变量的线程发送信号。
        // 该函数会依次遍历等待队列中的所有线程，并发送信号唤醒它们。
        return pthread_cond_broadcast(&m_cond) == 0;
    }

private:
    pthread_cond_t m_cond;
};

// 信号量类
class sem
{
public:
    sem()
    {
        if (sem_init(&m_sem, 0, 0) != 0)
        {
            throw std::exception();
        }
    }
    sem(int num)
    {
        if (sem_init(&m_sem, 0, num) != 0)
        {
            throw std::exception();
        }
    }
    ~sem()
    {
        sem_destroy(&m_sem);
    }
    // 等待信号量
    bool wait()
    {
        // 用于等待条件变量。
        // 该函数会在等待队列中等待条件变量的信号，直到被其他线程发送信号唤醒。
        // 如果被唤醒，则函数会返回 true；否则会一直等待，直到被唤醒或出现错误。
        return sem_wait(&m_sem) == 0;
    }
    // 增加信号量
    bool post()
    {
        // 用于释放一个信号量。该函数会将信号量的值加 1，并唤醒等待该信号量的线程。
        return sem_post(&m_sem) == 0;
    }

private:
    sem_t m_sem;
};

#endif